e40b0ebd849a47cfefbfa8b86a76565bd9f21bc9,src/org/pentaho/di/trans/steps/salesforceupsert/SalesforceUpsert.java,SalesforceUpsert,flushBuffers,#,168

Before Change


								com.sforce.soap.partner.Error err = data.upsertResult[j].getErrors()[i];
								errorMessage = errorMessage 
										+ ": Errors were found on item "
										+ new Integer(j).toString()
										+ " Error code is: "
										+ err.getStatusCode().toString()
										+ " Error message: " + err.getMessage();
						}
					}
					else 
					{
						if(log.isDetailed()) logDetailed("Found error from SalesForce and raising the exception"); 
						// for (int i = 0; i < data.upsertResult[j].getErrors().length; i++) {
							
						// Only throw the first error
						//
							com.sforce.soap.partner.Error err = data.upsertResult[j].getErrors()[0];
							throw new KettleException("Errors were found on item "
									+ new Integer(j).toString()
									+ " Error code is: "
									+ err.getStatusCode().toString()
									+ " Error message: " + err.getMessage());
							
						// } // for error messages
					}

After Change


				         for (int i = 0; i < data.upsertResult[j].getErrors().length; i++) {
								// get the next error
								com.sforce.soap.partner.Error err = data.upsertResult[j].getErrors()[i];
								errorMessage+= BaseMessages.getString(PKG, "SalesforceUpsert.Error.FlushBuffer", 
										new Integer(j), err.getStatusCode(), err.getMessage());
						}
					}
					else 
					{
						if(log.isDetailed()) logDetailed("Found error from SalesForce and raising the exception"); 
						// for (int i = 0; i < data.upsertResult[j].getErrors().length; i++) {
							
						// Only throw the first error
						//
							com.sforce.soap.partner.Error err = data.upsertResult[j].getErrors()[0];
							throw new KettleException( BaseMessages.getString(PKG, "SalesforceUpsert.Error.FlushBuffer", 
												new Integer(j), err.getStatusCode(), err.getMessage()));
							
						// } // for error messages
					}